google.golang.org/grpc.ClientConn.dopts (field)

83 uses

	google.golang.org/grpc (current package)
		balancer_wrapper.go#L89: 			DialCreds:       cc.dopts.copts.TransportCredentials,
		balancer_wrapper.go#L90: 			CredsBundle:     cc.dopts.copts.CredsBundle,
		balancer_wrapper.go#L91: 			Dialer:          cc.dopts.copts.Dialer,
		balancer_wrapper.go#L93: 			CustomUserAgent: cc.dopts.copts.UserAgent,
		balancer_wrapper.go#L446: 	if acbw.ccb.cc.dopts.disableHealthCheck {
		call.go#L32: 	opts = combine(cc.dopts.callOptions, opts)
		call.go#L34: 	if cc.dopts.unaryInt != nil {
		call.go#L35: 		return cc.dopts.unaryInt(ctx, method, args, reply, cc, invoke, opts...)
		clientconn.go#L189: 		dopts:  defaultDialOptions(),
		clientconn.go#L207: 			opt.apply(&cc.dopts)
		clientconn.go#L212: 		opt.apply(&cc.dopts)
		clientconn.go#L221: 		opt.DialOptionForTarget(cc.parsedTarget.URL).apply(&cc.dopts)
		clientconn.go#L231: 	if cc.dopts.defaultServiceConfigRawJSON != nil {
		clientconn.go#L232: 		scpr := parseServiceConfig(*cc.dopts.defaultServiceConfigRawJSON, cc.dopts.maxCallAttempts)
		clientconn.go#L236: 		cc.dopts.defaultServiceConfig, _ = scpr.Config.(*ServiceConfig)
		clientconn.go#L238: 	cc.keepaliveParams = cc.dopts.copts.KeepaliveParams
		clientconn.go#L253: 	cc.metricsRecorderList = istats.NewMetricsRecorderList(cc.dopts.copts.StatsHandlers)
		clientconn.go#L254: 	cc.statsHandler = istats.NewCombinedHandler(cc.dopts.copts.StatsHandlers...)
		clientconn.go#L257: 	cc.idlenessMgr = idle.NewManager((*idler)(cc), cc.dopts.idleTimeout)
		clientconn.go#L310: 	if !cc.dopts.block {
		clientconn.go#L314: 	if cc.dopts.timeout > 0 {
		clientconn.go#L316: 		ctx, cancel = context.WithTimeout(ctx, cc.dopts.timeout)
		clientconn.go#L325: 			case err == nil || !cc.dopts.returnLastError:
		clientconn.go#L342: 		} else if cc.dopts.copts.FailOnNonTempDialError && s == connectivity.TransientFailure {
		clientconn.go#L354: 			if err = cc.connectionError(); err != nil && cc.dopts.returnLastError {
		clientconn.go#L369: 	if cc.dopts.channelzParent != nil {
		clientconn.go#L483: 	if cc.dopts.copts.TransportCredentials == nil && cc.dopts.copts.CredsBundle == nil {
		clientconn.go#L486: 	if cc.dopts.copts.TransportCredentials != nil && cc.dopts.copts.CredsBundle != nil {
		clientconn.go#L489: 	if cc.dopts.copts.CredsBundle != nil && cc.dopts.copts.CredsBundle.TransportCredentials() == nil {
		clientconn.go#L492: 	transportCreds := cc.dopts.copts.TransportCredentials
		clientconn.go#L494: 		transportCreds = cc.dopts.copts.CredsBundle.TransportCredentials()
		clientconn.go#L497: 		for _, cd := range cc.dopts.copts.PerRPCCredentials {
		clientconn.go#L514: 	parentChannel, _ := cc.dopts.channelzParent.(*channelz.Channel)
		clientconn.go#L521: 	interceptors := cc.dopts.chainUnaryInts
		clientconn.go#L524: 	if cc.dopts.unaryInt != nil {
		clientconn.go#L525: 		interceptors = append([]UnaryClientInterceptor{cc.dopts.unaryInt}, interceptors...)
		clientconn.go#L537: 	cc.dopts.unaryInt = chainedInt
		clientconn.go#L552: 	interceptors := cc.dopts.chainStreamInts
		clientconn.go#L555: 	if cc.dopts.streamInt != nil {
		clientconn.go#L556: 		interceptors = append([]StreamClientInterceptor{cc.dopts.streamInt}, interceptors...)
		clientconn.go#L568: 	cc.dopts.streamInt = chainedInt
		clientconn.go#L677: 	dopts               dialOptions       // Default and user specified dial options.
		clientconn.go#L801: 	if cc.dopts.defaultServiceConfig != nil {
		clientconn.go#L802: 		cc.applyServiceConfigAndBalancer(cc.dopts.defaultServiceConfig, &defaultConfigSelector{cc.dopts.defaultServiceConfig})
		clientconn.go#L832: 	if cc.dopts.disableServiceConfig {
		clientconn.go#L913: 		dopts:        cc.dopts,
		clientconn.go#L1088: 	if cc.dopts.authority != "" {
		clientconn.go#L1089: 		return cc.dopts.authority
		clientconn.go#L1618: 	if ac.cc.dopts.disableHealthCheck {
		clientconn.go#L1809: 	for _, rb := range cc.dopts.resolvers {
		clientconn.go#L1855: 	defScheme := cc.dopts.defaultScheme
		clientconn.go#L1956: 	dopts := cc.dopts
		resolver_wrapper.go#L59: 		ignoreServiceConfig: cc.dopts.disableServiceConfig,
		resolver_wrapper.go#L76: 			DisableServiceConfig: ccr.cc.dopts.disableServiceConfig,
		resolver_wrapper.go#L77: 			DialCreds:            ccr.cc.dopts.copts.TransportCredentials,
		resolver_wrapper.go#L78: 			CredsBundle:          ccr.cc.dopts.copts.CredsBundle,
		resolver_wrapper.go#L79: 			Dialer:               ccr.cc.dopts.copts.Dialer,
		resolver_wrapper.go#L89: 		if ccr.cc.dopts.copts.Dialer != nil || !ccr.cc.dopts.useProxy {
		resolver_wrapper.go#L92: 			ccr.resolver, err = delegatingresolver.New(ccr.cc.parsedTarget, ccr, opts, ccr.cc.resolverBuilder, ccr.cc.dopts.enableLocalDNSResolution)
		resolver_wrapper.go#L185: 	return parseServiceConfig(scJSON, ccr.cc.dopts.maxCallAttempts)
		stream.go#L170: 	opts = combine(cc.dopts.callOptions, opts)
		stream.go#L172: 	if cc.dopts.streamInt != nil {
		stream.go#L173: 		return cc.dopts.streamInt(ctx, desc, cc, method, newClientStream, opts...)
		stream.go#L346: 	} else if cc.dopts.compressorV0 != nil {
		stream.go#L347: 		callHdr.SendCompress = cc.dopts.compressorV0.Type()
		stream.go#L348: 		compressorV0 = cc.dopts.compressorV0
		stream.go#L370: 	if !cc.dopts.disableRetry {
		stream.go#L376: 	if cc.dopts.binaryLogger != nil {
		stream.go#L377: 		if ml := cc.dopts.binaryLogger.GetMethodLogger(method); ml != nil {
		stream.go#L494: 		decompressorV0: cs.cc.dopts.dc,
		stream.go#L569: 	a.parser = parser{r: s, bufferPool: a.cs.cc.dopts.copts.BufferPool}
		stream.go#L706: 	if cs.cc.dopts.disableRetry {
		stream.go#L958: 	hdr, data, payload, pf, err := prepareMsg(m, cs.codec, cs.compressorV0, cs.compressorV1, cs.cc.dopts.copts.BufferPool)
		stream.go#L1334: 	} else if ac.cc.dopts.compressorV0 != nil {
		stream.go#L1335: 		callHdr.SendCompress = ac.cc.dopts.compressorV0.Type()
		stream.go#L1336: 		cp = ac.cc.dopts.compressorV0
		stream.go#L1354: 		decompressorV0:   ac.cc.dopts.dc,